package com.glsx.core.common;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class MsgConsumer {
	
	@KafkaListener(topics = {"test","my-topic"})
    public void processMessage(String content) {
        System.out.println("kafka-消费信息:"+content);
    }
}
